#include <linux/module.h>
#include <linux/init.h>
#include <linux/interrupt.h>
#include <linux/gpio.h>
#include <linux/delay.h>
#include <linux/workqueue.h>



/****
 * 
 *  自定义工作队列： 
 * 
//1.  创建工作队列, 给每个CPU都创建相关的工作队列   
struct workqueue_struct *  test_workqueue = create_workqueue("test_workqueu");

2.   创建工作任务
 struct work_struct  test_workqueue_work;
 
// 3. 调度中断下文
   queue_work(test_workqueue, &test_workqueue_work);

 4.   取消任务，释放队列


 自定义工作队列,   需要自己创建工作队列, 自己创建工作队列开销大， A生产线， B生成线， 可以处理多个任务
- 工作队列结构体 work_struct 
rk3568_r:/sdcard # busybox ps aux|grep test_workqueue
 5112 root       0:00 [test_workqueue]
 5130 root       0:00 grep test_workqueue

 
 */





int irq;
struct workqueue_struct *test_workqueue;
struct work_struct test_workqueue_work;


// 工作项处理函数
void test_work(struct work_struct *work)
{
  msleep(1000);
  printk("This is test_work\n");
}

// 中断处理函数
irqreturn_t test_interrupt(int irq, void *args)
{
  printk("This is test_interrupt\n");
  queue_work(test_workqueue, &test_workqueue_work); // 提交工作项到工作队列
  return IRQ_RETVAL(IRQ_HANDLED);
}

static int interrupt_irq_init(void)
{
  int ret;
  irq = gpio_to_irq(101); // 将GPIO映射为中断号
  printk("irq is %d\n", irq);

  // 请求中断
  ret = request_irq(irq, test_interrupt, IRQF_TRIGGER_RISING, "test", NULL);
  if (ret < 0)
  {
    printk("request_irq is error\n");
    return -1;
  }


  test_workqueue = create_workqueue("test_workqueue"); // 创建工作队列
  INIT_WORK(&test_workqueue_work, test_work);          // 初始化工作项

  return 0;
}

static void interrupt_irq_exit(void)
{
  free_irq(irq, NULL);                    // 释放中断
  cancel_work_sync(&test_workqueue_work); // 取消工作项
  flush_workqueue(test_workqueue);        // 刷新工作队列
  destroy_workqueue(test_workqueue);      // 销毁工作队列
  printk("bye bye\n");
}

module_init(interrupt_irq_init);
module_exit(interrupt_irq_exit);

MODULE_LICENSE("GPL");
MODULE_AUTHOR("topeet");